package com.atguigu.flink.process;

/**
 * Created by 黄凯 on 2023/6/18 0018 21:15
 *
 * @author 黄凯
 * 永远相信美好的事情总会发生.
 *
 * 1. 处理函数的功能
 *  *      1.1 继承自AbstractRichFunction ，拥有富函数的功能( 生命周期方法、 状态编程)
 *  *      1.2 基本处理数据的功能 processElement
 *  *      1.3 可以获取到TimerService,可以设置定时器
 *  *          配合ontimer方法，完成定时器触发后的逻辑处理。
 *  *      1.4 侧输出流
 *  *
 *  *  2. 处理函数的分类:
 *  *      2.1  ProcessFunction                 DataStream.process()
 *  *      2.2  KeyedProcessFunction            KeyedStream.process()
 *  *      2.3  ProcessWindowFunction           WindowedStream.process()
 *  *      2.4  ProcessAllWindowFunction        AllWindowedStream.process()
 *  *      2.5  CoProcessFunction               ConnectedStreams.process()
 *  *      2.6  ProcessJoinFunction             IntervalJoined.process()
 *  *      2.7  BroadcastProcessFunction        BroadcastConnectedStream.process()
 *  *      2.8  KeyedBroadcastProcessFunction   BroadcastConnectedStream.process()
 */
public class Flink01_ProcessFunction {
}
